package com.flying;

import org.apache.zookeeper.*;

public class Test1 {

    public static void main(String[] args) {
        String ip = "127.0.0.1:2181";
        try {
            // 创建一个与服务器的连接
            ZooKeeper zk = new ZooKeeper(ip,
                    100000, new Watcher() {
                // 监控所有被触发的事件
                public void process(WatchedEvent event) {
                    System.out.println("已经触发了" + event.getType() + "事件！");
                }
            });
//            // 创建一个目录节点
//            zk.create("/testRootPath", "testRootData".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,
//                    CreateMode.PERSISTENT);
////             创建一个子目录节点
//            zk.create("/testRootPath/testChildPathOne", "testChildDataOne".getBytes(),
//                    ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            System.out.println(new String(zk.getData("/testRootPath", false, null)));

            // 取出子目录节点列表
            System.out.println(zk.getChildren("/testRootPath", true));

            // 关闭连接
            zk.close();
        } catch (Exception e) {

            e.printStackTrace();
        }
    }
}
